package com.box.activemq.listener;

import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.box.service.search.SearchService;
import com.box.utils.ResponseResult;

/**   
*    
* 项目名称：MyBox   
* 类名称：BlogChangeMessageListener   
* 类描述：   接收消息的监听器，消息队列
* 创建人：君无邪   
* 创建时间：2019年11月20日 下午9:13:59   
* 修改备注：  https://www.java214.com 
* @version    1.0
*    
*/ 
@Component
public class BlogChangeMessageListener implements MessageListener{
	
	@Autowired
	private SearchService searchService;

	public void onMessage(Message message) {
		// TODO Auto-generated method stub
		//判断消息的类型是否为textmessage
		try {
			TextMessage textMessage=null;
	
			//获取博客id
			if(message instanceof TextMessage){
				
			
					textMessage=(TextMessage) message;
		Integer		blogId=Integer.parseInt(textMessage.getText());
				//向索引库添加文档
				ResponseResult result = searchService.updateSearchBlogById(blogId);
				
				System.out.println(result+"添加到索引库成功");
					
		
			
			}

		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
			System.out.println("添加失败:"+e);
		}
		
	}
	

}
